package com.hhf.rpc.easy.server.impl;

import com.hhf.rpc.easy.handler.HttpServerHandler;
import com.hhf.rpc.easy.server.HttpServer;
import io.vertx.core.Vertx;


/**
 * @Author hhf
 * @Date 2024/10/15
 * @Description Vertx实现
 */
public class VertxHttpServer implements HttpServer {

    @Override
    public void doStart(int port) {
        //1.创建vertx实例
        Vertx vertx = Vertx.vertx();
        //2.创建Http服务器
        io.vertx.core.http.HttpServer server = vertx.createHttpServer();
        //3.处理请求
        server.requestHandler(new HttpServerHandler());
        //4.启动服务器,并监听接口
        server.listen(port,result -> {
            if (result.succeeded()){
                System.out.println("vertx服务器 正在监听端口" + port);
            }else {
                System.out.println("vertx服务器 内部发生错误,终止监听:" + result.cause());
            }
        });
    }
}
